package com.jugheadzhou.core.message;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author jugheadzhou
 * @date 2021-09-28
 */
public interface CustomSource {

    /**
     * 自定义用于测试业务的输出通道进行通信
     */
    String OUTPUT = "test_output_channel";

    /**
     * 自定义输出管道
     *
     * @return
     */
    @Output(CustomSource.OUTPUT)
    MessageChannel output();

}
